package com.spic.business.mq.service;

//import com.rabbitmq.client.Channel;
//import com.rabbitmq.client.Connection;
import com.spic.business.mq.utils.ConnextionUtil;

import java.util.Scanner;

/**
 * @author 290512
 * @create 2022-05-13 15:50
 *
 * 测试类
 */
public class Sender
{
//    private final  static String EXCHANGE_NAME = "position_report_exchange";
//    public static void main(String[] args) throws Exception
//    {
//        //获取连接
//        Connection connection = ConnextionUtil.getConnection();
//
//        //创建通道
//        Channel channel = connection.createChannel();
//
//        //声明队列 ，若果队列不存在什么也不做 不存在则创建
//        //1 队列名字
//        //2 是否持久化队列 false 重启丢失消息  true 消息会持久化到erlang 自带数据库中
//        //3是否排外 两个作用 当我们连接关闭是否会自动删除队列，作用二是否私有当前队列，如果私有其他通道不可访问当前队列，如果为TRUE一般一个队列只适用于一个消费者的时候
//        //4 是否自动删除 5 其他参数
//
//        channel.exchangeDeclare(EXCHANGE_NAME,"topic");
//        Scanner scanner = new Scanner(System.in);
//        while (scanner.hasNext()){
//            String message = scanner.next();
//            String json = "{\"UTCtime\":1648172719976,\"equipmentSn\":1,\"equipmentName\":\"1701测试车\",\"equipmentTypeName\":\"矿卡\",\"longitude\":119.6114773,\"latitude\":45.5018378,\"altitude\":0.824523985385,\"direction\":69.57270050048828,\"speed\":30.0}";
//            channel.basicPublish(EXCHANGE_NAME,"position.report.notify",null,json.getBytes());
//            System.out.println("发送消息完成:"+message);
//        }
//        //关闭连接
//        channel.close();
//        connection.close();
//    }
}
